package com.simple.datax.seda.core.event;
import com.simple.datax.seda.api.QueueElementIF;
import com.simple.datax.seda.api.StageWrapperIF;
public class HeartbeatEvent implements QueueElementIF {
	StageWrapperIF sourceStage = null;
	long startTime;

	public HeartbeatEvent(StageWrapperIF sourceStage) {
		this.sourceStage = sourceStage;
		this.startTime = System.currentTimeMillis();
	}

	public void report() {
		sourceStage.putEvent(new ReportEvent(this));
	}

	public long getStartTime() {
		return startTime;
	}
}
